package com.siss.tenancy.elastic.config;

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component
public class RocketMqSender {

    @Autowired
    RocketMQTemplate rocketMQTemplate;

    public void sendTransaction(String topic, Message<?> message,Object param){
        rocketMQTemplate.sendMessageInTransaction(topic,message,param);
    }

}
